package com.crazywolf.kafka;

/**
 * @auth GaoJianwen
 * @date 2016/2/2.
 */
public class Client {

    public static void main(String[] args) {
        String topic = "gaojianwen";
        new KafkaProducer(topic).start();
        new KafkaConsumer(topic).start();

    }
}
